#coding:utf8

from celery import Celery

#让Celery加载当前工程的配置文件
import os
if not os.getenv('DJANGO_SETTINGS_MODULE'):
    os.environ['DJANGO_SETTINGS_MODULE'] = 'mall.settings'

#创建Celery对象
app = Celery('celery_tasks')

#设置
app.config_from_object('celery_tasks.conf')

#自动检测任务
app.autodiscover_tasks(['celery_tasks.sms','celery_tasks.email'])

#我们需要指令让Celery单独执行
#需要在虚拟环境中执行
# celery -A celery对象的路径 worker -l info
#执行任务
#celery -A celery_tasks.main worker -l info
